package com.example.studymoudle.observer_design_pattern;

public abstract class BaseicFusableObserver<T,U> implements Observer<T>{

    //观察者
    protected final Observer<U> actual;

    protected BaseicFusableObserver(Observer<U> actual) {
        this.actual = actual;
    }


    @Override
    public void onSubscribe() {
        actual.onSubscribe();
    }

    @Override
    public void onError(Throwable e) {
        actual.onError(e);
    }

    @Override
    public void onComplete() {
        actual.onComplete();
    }
}
